//获取数据库的配置
const {dbconfig} = require('../config.js');
const mysql = require('mysql');
//创建数据库连接池对象
const pool = mysql.createPool(dbconfig);

let db ={};

//执行sql语句,并返回执行后的结果
db.q = (sql,params) =>{
	return new Promise((resolve,reject) =>{
		//从数据库连接池，拿出一个连接对象
		pool.getConnection((error,connection) =>{
			//如果获取连接对象失败，就把失败信息传递给error
			if(error){
				reject(error);
				return;
			}
			//如果获取成功，连接对象传递给connection参数
			connection.query(sql,params,(error,result) =>{
				if(error){
					reject(error);
					return;
				}
				resolve(result);
			})
		})
	})
}
module.exports = db;